package com.jzl.canal_consumer.etl.et.rocketmq.transform;

import java.util.List;

/**
 * @author ZhenWuWang
 */
public interface MqDataTransform<E, T>
{
    List<T> transform(String schemaName, List<E> list);
}
